package com.ldj.rocketmq.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.function.Consumer;

/**
 * User: ldj
 * Date: 2024/5/27
 * Time: 17:54
 * Description: No Description
 */
@Slf4j
@Configuration
public class StreamConsumer {

    @Bean
    public Consumer<String> listener() {
        return message -> {
            log.info("demoChannel接到消息：{}", message);
        };
    }

}
